package com.catmiao.sql;


import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;
import scala.Serializable;


/**
 * dsl语法访问
 */
public class Spark07_Model_dsl implements Serializable {

    public static void main(String[] args) {

        // 构建SparkSQL的环境对象时，一般采用构建器模式
        // 构造器模式：构建对象
        SparkSession sparkSession = SparkSession
                .builder()
                .master("local[*]")
                .appName("SparkSQL")
                .getOrCreate();


        Dataset<Row> dataset = sparkSession.read().json("datas/sql/user.json");

        dataset.select("*").show();


        sparkSession.close();
    }

}


